package com.kantboot.functional.im.service;

import com.kantboot.functional.im.dto.FunctionalImPushMessageDTO;

/**
 * 关于websocket的服务
 */
public interface IFunctionalImPushMessageService {

    /**
     * 发送消息
     */
    void push(FunctionalImPushMessageDTO message);

    /**
     * 给broker改变状态编码
     */
    void changeStatusCode(Long brokerId, String statusCode);

}
